package com.ydl.learning.flink.demo.transformations

import com.ydl.learning.flink.demo.Utils
import org.apache.flink.streaming.api.scala._

/**
 * flatMap
 * 拍平
 *
 * @author ydl
 * @since 2020/9/21
 */
object FlatMapDemo extends Utils{
  def main(args: Array[String]): Unit = {
    val tuple = getSocketTextStream(9999)
    tuple._2.flatMap(_.split(" ")).print()
    tuple._1.execute("start")
  }
}
